package cn.ac.iie.di.ban.ycl.cleaner.receiver;

import cn.ac.iie.di.datadock.rdata.exchange.client.core.session.receive.REAbstractReceiveMessageHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @author zmc <zhangmingcheng@iie.ac.cn>
 * @date 2016-9-14 12:25:13
 * @version V1.0
 * @desc    接收错误消息
 */
public class MessageFailReceiver extends REAbstractReceiveMessageHandler<byte[]> {

    static final Logger LOG = LoggerFactory.getLogger(MessageFailReceiver.class);

    @Override
    public boolean handle(byte[] message) {
        LOG.error("receive message error ! size=" + message.length + " message=" 
                + new String(message));
        return true;
    }
}
